import com.sun.tracing.dtrace.FunctionAttributes;
import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext;
import org.apache.rocketmq.common.message.MessageExt;

import java.util.List;
@FunctionalInterface
public interface MyMessageListener {
    String consumeMessage(String name);
}
